/*
 * Copyright (C), 2002-2021, 苏宁易购电子商务有限公司
 * FileName: KafkaSender.java
 * Author:   zhangc
 * Date:     2021/11/05 15:55
 * Description: //模块目的、功能描述
 * History: //修改记录
 * <author>      <time>      <version>    <desc>
 * 修改人姓名    修改时间    版本号       描述
 */
package com.zhangc.kafkatest.kafka;

import javax.annotation.Resource;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

import com.alibaba.fastjson.JSON;

/**
 * 功能描述:<br>
 *
 * @author zhangc
 * @see [相关类/方法]（可选）
 * @since [产品/模块版本] （可选）
 */
@Component
public class KafkaSender {

    @Value("${kafka.test.topic}")
    String testTopic;

    @Resource
    private KafkaTemplate<String, String> kafkaTemplate;

    /**
     * 发送文字消息
     *
     * @param message
     * @return
     */
    public String sendStr(String message) {
        kafkaTemplate.send(testTopic, message);
        return message;
    }

    /**
     * 发送对象消息
     *
     * @param obj
     * @return
     */
    public String sendObj(Object obj) {
        String message = JSON.toJSONString(obj);
        kafkaTemplate.send(testTopic, message);
        return message;
    }
}
